package com.lry.mqstarter.annotation;


import com.lry.message.MessageModel;

import java.lang.annotation.*;


@Target({ ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RocketMQListener {

    String nameSrvAddr() default "";

    String consumerGroup();

    String topic();

    String instanceName()default "";

    int consumeMessageBatchMaxSize() default 1;

    String subExpression() default "";

    MessageModel messageModel() default MessageModel.CLUSTERING;
}
